package com.hins.mq.rocketmq;

import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;

public interface IConsumer {
    DefaultMQPushConsumer getConsumer() throws Exception;
}
